﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
using Model;

namespace DAO_Layer
{
    class MySqlDaoTrabajador:DAO_Trabajador
    {
        private String TableName = "Trabajador";
        Sqlconnector mysqlconn;

        public MySqlDaoTrabajador()
        {
            mysqlconn = new Sqlconnector();
        }

        public List<Model.Trabajador> queryAll()
        {
            List<Trabajador> list = new List<Trabajador>();

            mysqlconn.Open();

            MySqlCommand comm = new MySqlCommand();
            comm.Connection = mysqlconn.Mysqlconnection;
            comm.CommandText = "SELECT * FROM " + TableName;
            MySqlDataReader myReader = null;

            try
            {
                myReader = comm.ExecuteReader();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }

            while (myReader.Read())
            {

                Trabajador t = new Trabajador();
                t.Id = Int32.Parse(myReader["Id"].ToString());
                t.Nombre = myReader["Nombre"].ToString();
                t.ApPaterno = myReader["ApPaterno"].ToString();
                t.ApMaterno = myReader["ApMaterno"].ToString();
                t.Dni=myReader["DNI"].ToString();
                t.Estado = myReader["Estado"].ToString();
                list.Add(t);
            }

            myReader.Close();
            mysqlconn.Close();

            return list;

        }
    }
}
